package com.pty.mainservice.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Created by pty on 2017/12/25
 */
@Configuration
public class ReceiveConfig {

    @Bean
    public Queue queue() {
        return new Queue("queue");
    }

    @Bean
    public Queue queueBean() {
        return new Queue("queueBean");
    }

    @Bean(name = "message")
    public Queue queueTopic() {
        return new Queue("topic.message");
    }

    @Bean(name = "messages")
    public Queue queueTopics() {
        return new Queue("topic.messages");
    }

    @Bean(name = "messagea")
    public Queue queueTopica() {
        return new Queue("topic.messagea");
    }

}
